package cn.thread;


import java.util.concurrent.*;

public class TestForkJoin {


    public static void main(String[] args) {
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(2, 10, 0L, TimeUnit.SECONDS, new PriorityBlockingQueue<>());
        threadPoolExecutor.execute(new Runnable() {
            @Override
            public void run() {
                for (int i = 0; i < 100; i++) {

                    System.out.println(i);
                }
            }
        });

    }



}
